package threads;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.Serializable;
import java.net.Socket;


import mensagens.Mensagem;


public class ReceptorDadosServidor extends ReceptorDados implements Serializable {


	/**
	 * 
	 */
	private static final long serialVersionUID = 8855366846997540883L;

	public ReceptorDadosServidor(int porta) throws IOException{
		super(porta);		
	}
	
	@Override
	public void run() {
		while (true){
			try {
				Socket cliente = super.getSocket().accept();
				//System.out.println(cliente.getRemoteSocketAddress());
				
				ObjectInputStream input = new ObjectInputStream(cliente.getInputStream());
				
				Mensagem mensagem;
	
				mensagem = (Mensagem) input.readObject();			
				
				mensagem.tratarMensagemComoServidor();
				
				
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}catch (ClassNotFoundException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}
